package com.z2.disruptor.comsumer;

import com.z2.disruptor.event.LongEvent;
import com.lmax.disruptor.WorkHandler;

/**
 * Created by cdyizuoming on 2017/11/9.
 */
public class LongEventPoolHandler implements WorkHandler<LongEvent> {

    public void onEvent(LongEvent event) throws Exception {
        final String threadName = Thread.currentThread().getName();
        final Long ID = event.get();
        System.out.println(ID + "consumer 线程:" + threadName + " Event: value=" + event.get());
    }
}
